package org.lql.chaos.kafka.example.design;

import org.springframework.kafka.support.SendResult;
import org.springframework.util.concurrent.ListenableFuture;

/**
 * @author: liangqinglong
 * @date: 2025-08-10 14:33
 * @description: 统一消息发送接口
 **/
public interface MessageProducerService {

	<K, V> ListenableFuture<SendResult<K, V>> send(String topic, K key, V payload, String serializationType, String partitionStrategy);

}
